package com.youxin.dataStream.broadcast;

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.datastream.KeyedStream;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flink.streaming.api.datastream.WindowedStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;
import scala.Tuple2;

/**
 * 广播变量（不可变），要是想变的话可以考虑其他的方式
 * 官方网站没有提供广播变量相关的方法
 * 以下方式是否能用还是值得商榷的
 *
 * 网上的例子都是使用使用广播变量注册成流，然后流进行connect, 然后调用process
 */
public class StreamBroadcast {
    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStreamSource<String> lines = env.socketTextStream("hadoop-1", 9999);

        //lines.map(new )


    }
}
